package com.hss.rxjava;

public interface Observable<T> {
    Observable<T> doNext(Action<T> action);
    <R> Observable<R> map(Fun1<T,R> fun1);
    Disposable subscribe(Consumer<? super  T> consumer);
}
